package ins.framework.kafkastream.processor;

import org.apache.kafka.streams.processor.Processor;
import org.apache.kafka.streams.processor.ProcessorContext;

public class ProcessorB implements Processor<String, String> {
    @Override
    public void init(ProcessorContext processorContext) {

    }

    @Override
    public void process(String key, String value) {
        String line = key + "MyProcessor  B  ----   "+value;
        System.out.println(line);
    }
    @Override
    public void punctuate(long timestamp) {

    }

    @Override
    public void close() {

    }

}
